// 导入MySQL模块
var mysql = require('mysql');
var dbConfig = require('../db/DBConfig');
var userSQL = require('../db/UserSQL');
// 使用DBConfig.js的配置信息创建一个MySQL连接池
var pool = mysql.createPool( dbConfig.mysql );

function matching(values){
    return new Promise((resolve,reject) => {
        console.log(values,'进来了吗1');
        pool.getConnection(function(err, connection) {
            if (err) {
                reject(err)
            } else {
                connection.query(userSQL.matching,values, (err, rows) => {
                    console.log(values,'进来了吗2');
                    if (err) {
                        reject(err);
                        console.log(err,'报错');
                    } else {
                        if(rows.length >= 1) {
                            resolve(rows);
                            console.log(rows,'有找到用户返回密码');
                        }else {
                            resolve(rows);
                            console.log(rows,'未找到用户返回空包');
                        }
                    }
                    // 结束会话
                    connection.release();
                })
            }
        })
    })
};
function get_user_data(values) {
    return new Promise((resolve,reject) => {
        console.log(values,'进来了吗1');
        pool.getConnection(function(err, connection) {
            if (err) {
                reject(err)
            } else {
                connection.query(userSQL.get_user_data,values, (err, rows) => {
                    console.log(values,'进来了吗2');
                    if (err) {
                        reject(err);
                        console.log(err,'报错');
                    } else {
                        if(rows.length >= 1) {
                            resolve(rows);
                            console.log(rows,'有找到用户返回用户数据');
                        }else {
                            resolve(rows);
                            console.log(rows,'未找到用户返回空包');
                        }
                    }
                    // 结束会话
                    connection.release();
                })
            }
        })
    })
};
function get_club_data(values) {
    return new Promise((resolve,reject) => {
        console.log(values,'进来了吗1');
        pool.getConnection(function(err, connection) {
            if (err) {
                reject(err)
            } else {
                connection.query(userSQL.get_club_data,values, (err, rows) => {
                    console.log(values,'进来了吗2');
                    if (err) {
                        reject(err);
                        console.log(err,'报错');
                    } else {
                        if(rows.length >= 1) {
                            resolve(rows);
                            console.log(rows,'有找到公会返回公会数据');
                        }else {
                            resolve(rows);
                            console.log(rows,'未找到用户返回空包');
                        }
                    }
                    // 结束会话
                    connection.release();
                })
            }
        })
    })
};
module.exports = {matching,get_user_data,get_club_data};